package com.atguigu.rabbitmq.three;
import com.atguigu.rabbitmq.util.RabbitMqUtils;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.MessageProperties;

import java.io.IOException;
import java.util.Scanner;
import java.util.concurrent.TimeoutException;
// p25
/**
 * 消息在手动应答时是不丢失,放回队列中重新消费
 *
 * 消息应答
 * 消费者完成一个任务可能需要一段时间,如果其中一个消费者处理一个长的任务并
 * 仅只完成了部分突然它挂掉了,会发生什么情况。RabbitMQ一旦向消费者传递了一条消息,
 * 便立即将该消息标记为删除。在这种情况下,突然有个消息挂掉了,我们将丢失正在处理的消息。
 * 以及后续发送给该消费者的消息,因为它无法接收到。
 *
 * 为了保证消息在发送过程中不丢失,rabbitmq引入消息应答机制,消息应答就是:
 * 消费者在接收到消息并且处理该消息之后,告诉rabbitmq它已经处理了,rabbitmq可以把
 * 该消息删除了。
 *
 * 自动应答(企业开发中不推荐使用)
 * 消息发送后立即被任务已经传送成功,这种模式需要在高吞吐量和数据传输安全性
 * 方面做权衡,因为这种模式如果消息在接收到之前,消费者那边出现或channel关闭,
 * 那么消息就丢失了,当然另一方面这种模式消费者那边可以传递过载的消息,
 * 没有对传递的消息数量进行限制,当然这样有可能使得消费者这边由于接收太多还
 * 来不及处理的消息,导致这些消息的积压,最终使得内存耗尽,最终这些消费者被操作系统杀死，
 * 所以这种模式仅适用在消费者可以高效并以某种速率能够处理这些消息的情况下使用。
 *
 * 推荐手动应答,代码如下
 *
 * 中间有个消息自动重新入队的概念
 * 如果消费者由于某些原因失去连接(其通道已关闭,连接已关闭或TCP连接丢失),导致消息
 * 未发送ACK确认,RabbitMQ将了解到消息未完全处理,并将对其重新排队。
 * 如果此时其他消费者可以处理,它将很快将其重新分发给另一个消费者。
 * 这样,即使某个消费者偶尔死亡,也可以确保不会丢失任何消息。
 */
public class Task02 {

    //队列名称
    public static final String TASK_QUEUE_NAME = "ack_queue";


    public static void main(String[] args) throws IOException, TimeoutException {

        Channel channel = RabbitMqUtils.getChanner();
        /**
         * 生成一个队列
         * 参数1: 队列名词
         * 参数2: 队列里面的消息,是否需要持久化,默认情况下消息存储在内存中,持久化是存储在磁盘上。
         *          true是持久化,false不持久化
         *
         * 参数3: 该队列是否只供一个消费者进行消费 是否进行消息的共享,true可以多个消费者消费。
         *          false只能一个消费者消费
         *
         * 参数4: 是否自动删除,最后一个消费者端开连接以后,该队列是否自动删除
         *          true自动删除  false不自动删除
         *
         * 参数5: 其它参数
         */
        boolean durable = true; //让Queue(队列)进行持久化
        /**
         * RabbitMQ持久化
         *  概念:
         *      RabbitMQ设置手动应答以后,可以保证处理任务不丢失。
         *      但是如何保障当RabbitMQ服务停掉以后消息生成者发送过去的消息不丢失。
         *      默认情况下RabbitMQ退出或由于某种原因崩溃时,它忽视队列和消息,除非告知它
         *      不要这样做。确保消息不会丢失需要做两件事: 我们需要将队列和消息都标记为持久化。
         *
         *
         *      将消息标记为持久化并不能完全保证不会丢失消息。尽管它告诉RabbitMQ将消息保存到磁盘,
         *      但是这里依然存在当消息准备存储在磁盘的时候,但是还没有存储完,消息还在缓存这的一个间隔点。
         *      此时并没有真正写入磁盘。持久性保证并不强,但是对于我们的简单任务队列而言，这已经绰绰有余了。
         *      如果需要更强有力的持久化策略。
         *
         */
        channel.queueDeclare(TASK_QUEUE_NAME, durable, false, false, null);

        //从控制台中输入信息
        Scanner scanner = new Scanner(System.in);


        /**
         * 消息实现持久化
         * 发送消息添加MessageProperties.PERSISTENT_TEXT_PLAIN这个属性
         */
        while (scanner.hasNext()) {
            String message = scanner.next();
            //设置生产者发送消息未持久化消息(要求保存到磁盘上),一般是保存在内存中,消息存在丢失的可能
            channel.basicPublish("", TASK_QUEUE_NAME, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes("UTF-8"));
            System.out.println("生产者发出消息:" + message);
        }


    }



}